package com.yl.flink.redis;

import org.apache.flink.api.common.functions.Function;

import java.io.Serializable;

public interface RedisMapper<T> extends Function, Serializable {

    RedisCmdDesc getCmdDesc();

    String getKeyFromData(T var1);

    String getValueFromData(T var1);

    int getTtlFromData(T var1);
}
